package hhh.app.domain.interactor;

import hhh.app.domain.repository.ProductRepository;
import rx.Observable;

/**
 * Created by Administrator on 2017/5/12 0012.
 */
public class GetProductReview extends ProductCase {
    private final ProductRepository productRepository;
    private int pid;

    public GetProductReview(ProductRepository productRepository) {
        this.productRepository = productRepository;
    }

    public GetProductReview setPid(int id){
        pid=id;
        return this;
    }

    @Override
    protected Observable buildProductCaseSubscriber() {
        return productRepository.productReviews(pid);
    }
}
